/*
package com.giraffe.mqtt.listener;

import com.giraffe.mqtt.controller.TestController;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;

*/
/**
 * @Author ldx
 * @Date 2024/01/18 19:14
 **//*

@Component
@RocketMQMessageListener(topic = "TOPIC_GIRAFFE_CENTER", consumerGroup = "GROUP_GIRAFFE_CENTER")
public class MqttTopicConsumer implements RocketMQListener<String> {

    @Resource
    TestController testController;

    @Override
    public void onMessage(String s) {
        System.out.println(s);
        testController.send(s);
    }
}
*/
